//package org.way.rocketMq.bean;
//
//import org.springframework.context.EnvironmentAware;
//import org.springframework.core.env.Environment;
//import org.way.rocketMq.dto.MqConstant;
//
//public class RocketManager implements EnvironmentAware {
//
//    private Environment env;
//
//    @Override
//    public void setEnvironment(Environment environment) {
//        this.env = environment;
//    }
//
//    public String getTopicValue() {
//        String profile = env.getActiveProfiles()[0];
//        return String.join("_", MqConstant.topic,profile);
//    }
//
//    public String getConsumerGroupValue() {
//        String profile = env.getActiveProfiles()[0];
//        return String.join("_", MqConstant.consumerGroup,profile);
//    }
//}
